package com.huangfuyi.process.actuator.definition.defaultimpl;

import com.huangfuyi.process.actuator.definition.EPScheduler;
import com.huangfuyi.process.entity.mainthread.EPSchedulerInfo;

public class EPDefaultScheduler extends EPScheduler {

    @Override
    public void submit(EPSchedulerInfo schedulerConfig) {
        runNowInCurrentNode(schedulerConfig);
    }

    @Override
    public void cancel(EPSchedulerInfo schedulerConfig) {

    }

    @Override
    public void runNow(EPSchedulerInfo schedulerConfig) {
        runNowInCurrentNode(schedulerConfig);
    }

}
